package jobs;

import org.apache.hadoop.io.Text;

import domain.TextPair;

public class JoinPartitioner extends org.apache.hadoop.mapreduce.Partitioner<Text,TextPair>{

	@Override
	public int getPartition(Text key, TextPair values, int numPartitions) {
		return (key.hashCode() & Integer.MAX_VALUE ) % numPartitions ;
	}
}
